//package com.xiyu.service.framework.websocket.core.sender.rabbitmq;
//
//import lombok.RequiredArgsConstructor;
//import org.springframework.amqp.core.ExchangeTypes;
//import org.springframework.amqp.rabbit.annotation.*;
//
///**
// * {@link RabbitMQWebSocketMessage} 广播消息的消费者，真正把消息发送出去
// *
// * @author 芋道源码
// */
//@RabbitListener(
//        bindings = @QueueBinding(
//                value = @Queue(
//                        // 在 Queue 的名字上，使用 UUID 生成其后缀。这样，启动的 Consumer 的 Queue 不同，以达到广播消费的目的
//                        name = "${xiyu.websocket.sender-rabbitmq.queue}" + "-" + "#{T(java.util.UUID).randomUUID()}",
//                        // Consumer 关闭时，该队列就可以被自动删除了
//                        autoDelete = "true"
//                ),
//                exchange = @Exchange(
//                        name = "${xiyu.websocket.sender-rabbitmq.exchange}",
//                        type = ExchangeTypes.TOPIC,
//                        declare = "false"
//                )
//        )
//)
//@RequiredArgsConstructor
//public class RabbitMQWebSocketMessageConsumer {
//
//    private final RabbitMQWebSocketMessageSender rabbitMQWebSocketMessageSender;
//
//    @RabbitHandler
//    public void onMessage(RabbitMQWebSocketMessage message) {
//        rabbitMQWebSocketMessageSender.send(message.getSessionId(),
//                message.getUserType(), message.getUserId(),
//                message.getMessageType(), message.getMessageContent());
//    }
//
//}
